package com.xjj.sso.server.rabbitmq;

import com.xjj.sso.server.util.JsonUtil;



public class TestProducer {

	public static void main(String[] args) throws Exception {

		
		for (int i = 0; i < 10; i++) {

			Producer p = new Producer("sso.logout");
			MqMessage msg = new MqMessage("logout", "fuck_ticket_id----"+i);
			String jsonMsg = JsonUtil.toJSONString(msg);
			p.sendMessage(jsonMsg.getBytes("utf-8"));

			Producer p2 = new Producer("sso.logout");
			MqMessage msg2 = new MqMessage("logout", "fuck_ticket_id----"+i);
			String jsonMsg2 = JsonUtil.toJSONString(msg2);
			p2.sendMessage(jsonMsg.getBytes("utf-8"));
		}
	}
}
